package com.caption.mq.listener;

import com.caption.mq.entity.ModelResult;
import com.caption.mq.entity.MqMessageDTO;
import com.caption.mq.entity.MqSubscribeDO;
import org.apache.rocketmq.common.message.MessageExt;
import org.springframework.web.client.RestTemplate;

public class RocketMQListener extends AbstractMqListener{


    public RocketMQListener(MqSubscribeDO mqSubscribeDO, RestTemplate restTemplate) {
        super(mqSubscribeDO, restTemplate);
    }

    @Override
    public void onMessageHandleSuccess(MessageExt messageExt, MqMessageDTO messageDTO, ModelResult modelResult) {

    }

    @Override
    public void onMessageHandleFailed(MessageExt messageExt, MqMessageDTO messageDTO, ModelResult modelResult) {

    }

    @Override
    public void onMessageHandleException(MessageExt messageExt, MqMessageDTO messageDTO, Exception e) {

    }
}
